package com.msb.business.consumer;

import com.msb.business.api.mq.topic.DemoTopic;
import com.msb.framework.mq.annotation.Consumer;
import lombok.extern.slf4j.Slf4j;

@Slf4j
@Consumer
public class DemoConsumer implements DemoTopic {
    @Override
    public void consume(String message) {
        log.info("接收到消息：{}", message);
    }
}
